package cn.virens.cmpt.rabbit;

import java.io.IOException;

import cn.virens.cmpt.rabbit.packet.RabbitPacket;
import cn.virens.cmpt.rabbit.packet.reply.RabbitPacketReply;

public interface RabbitManager {

	/** 交换中心 */
	String getExchange();

	/** 路由规则 */
	String getRoutingKey();

	void send(RabbitPacket packet) throws Exception;

	void sendRabbit(RabbitPacket packet) throws IOException;

	void sendRabbit(String routingKey, RabbitPacket packet) throws IOException;

	void sendRabbit(String exchange, String routingKey, RabbitPacket packet) throws IOException;

	void sendReply(RabbitConsumerProps props, RabbitPacketReply packetReply) throws IOException;

}
